package com.topsun.framework.common.kafka.pojo;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

/**
 * @author: 皮皮
 * @date: 2021/7/16 3:10 PM
 */
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@ApiModel("消息结果实体")
public class MessageResult<K, V> {

    @ApiModelProperty("topic")
    private String topic;

    @ApiModelProperty("message")
    private Message<K, V> message;

    @ApiModelProperty("分区")
    private Integer partition;

    @ApiModelProperty("偏移量")
    private Long offset;

    @ApiModelProperty("时间戳")
    private Long timestamp;

}
